package org.myfram.flink.flinkonjar.common.config;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.myfram.flink.flinkonjar.common.properties.HBaseProperties;

public class HBaseConfig {

    public static Configuration getSourceConf(HBaseProperties prop) {
        Configuration configuration = HBaseConfiguration.create();
        configuration.set("hbase.zookeeper.quorum", prop.getZookeeperQuorum());
        configuration.set("hbase.zookeeper.property.clientPort", prop.getPropertyClientPort());
        return configuration;
    }

}
